//挂载mysql
const mysql = require('mysql')

//创建数据库连接池
const pool = mysql.createPool({
  host: 'localhost',  // 端口号
  user: 'root',       // 账户
  password: '253547', // 密码
  database: 'node'    // 表名
})

// 封装异步操作
let query = function (sql, values) {
  return new Promise((resolve, reject) => {
    pool.getConnection(function (err, connection) {
      if (err) {
        reject(err)
      } else {
        connection.query(sql, values, (err, rows) => {
          if (err) {
            reject(err)
          } else {
            resolve(rows)
          }
          connection.release()
        })
      }
    })
  })
}

module.exports = { query }